package mylab.starters.mq.api;

public interface Producer extends Client {
    /**
     * 发送消息前需要先启动
     */
    void start();

    /**
     * 不再需要发消息时可以停用，以节省资源
     */
    void stop();

    /**
     * 发送消息
     *
     * @param message 待发送的消息
     * @return
     */
    Object send(Message message);

}
